package com.enjoyor.soa.traffic.api.service.dubbo.kafka;

import com.enjoyor.soa.traffic.util.pojo.ResultPojo;

/**
 * redis消息发布
 * @ClassName: PubMsgService
 * @Description: TODO
 * @author: Administrator
 * @date: 2018年10月26日 下午2:23:38
 */
//@Service(protocol = { "dubbo" })
public interface DubboKafkaToolService {
	/**
	 * 
	 * @Title: registerSend
	 * @Description: 初始化发布
	 * @param topic
	 * @return
	 * @return: ResultPojo
	 */
	public ResultPojo initSend(String topic);

	/**
	 * 
	 * @Title: send
	 * @Description: 发布消息
	 * @param topic
	 * @param message
	 * @return
	 * @return: ResultPojo
	 */
	public ResultPojo send(String topic, String key, String message);
	
	
	/**
	 * 
	 * @Title: receive
	 * @Description: 初始化订阅
	 * @param topic
	 * @param groupid
	 * @return: void
	 */
	public void initReceive(String topic, String groupid);
	
	/**
	 * 
	 * @Title: setListenFlag
	 * @Description: TODO
	 * @param topic
	 * @param flag
	 * @return: void
	 */
	public void setListenFlag(String system, String topic, String groupid, boolean flag);
}
